package org.example.elastic.lite.config;

import com.dangdang.ddframe.job.executor.ShardingContexts;
import com.dangdang.ddframe.job.lite.api.listener.AbstractDistributeOnceElasticJobListener;

/**
 * elastc job 监听器
 *
 * 实现分布式任务监听器
 * 如果任务有分片，分布式监听器会在开始和结束的时候各执行一次
 *
 * @author 魏荣杰
 * @date 2022/11/11 01:53
 * @since
 * @version
 */
public class DynamicElasticJobListener extends AbstractDistributeOnceElasticJobListener {

    public DynamicElasticJobListener(long startedTimeoutMilliseconds, long completedTimeoutMilliseconds) {
        super(startedTimeoutMilliseconds, completedTimeoutMilliseconds);
    }

    @Override
    public void doBeforeJobExecutedAtLastStarted(ShardingContexts shardingContexts) {

    }

    @Override
    public void doAfterJobExecutedAtLastCompleted(ShardingContexts shardingContexts) {

    }

}
